//package cn.enjoy.rabbitmq.handler.boot;
//
//import com.rabbitmq.client.Channel;
//import lombok.extern.slf4j.Slf4j;
//import org.springframework.amqp.core.Message;
//import org.springframework.amqp.rabbit.annotation.RabbitHandler;
//import org.springframework.amqp.rabbit.annotation.RabbitListener;
//import org.springframework.stereotype.Component;
//
//import java.util.Map;
//
///**
// * Time To Live 消息存活队列，队列中的消息过期后销毁
// *
// * @author K
// * @date 2020/11/30 14:09
// */
//@Slf4j
//@Component
//@RabbitListener(queues = "ttl.queue")
//public class TTLQueueHandler {
//
//    @RabbitHandler
//    public void ttlQueueAck(Map msg, Message message, Channel channel) {
//        long deliveryTag = message.getMessageProperties().getDeliveryTag();
//        try {
//            log.info("TTL队列 ttl.queue 接收消息：{}", msg.toString());
//            channel.basicAck(deliveryTag, false);
//        } catch (Exception e) {
//            try {
//                channel.basicNack(deliveryTag, false, true);
//            } catch (Exception ex) {
//                ex.printStackTrace();
//            }
//        }
//    }
//
//}
